#pragma once
#include "mqclient.h"
#include "amqp.h"
#include "amqp_tcp_socket.h"

namespace MqClient
{
class CRabbitMqProducer : public CMQProducer
{
public:
    virtual bool Send(string event);

    bool Connect();
    void DisConnect();
    bool Send(string event, int num);
public:
    amqp_connection_state_t _conn;

};
}